package org.mcclone.jr.spark.fs;

import org.apache.spark.sql.SparkSession;

public class ParquetMerger {

    public static void main(String[] args) {
        SparkSession spark = SparkSession
                .builder()
                .master("local")
                .appName("Java Spark SQL basic example")
                .getOrCreate();
        spark.read().parquet("/data/person.parquet/type=1").show();
//                .write().partitionBy("type").parquet("/data/result/person.parquet");
    }
}
